//package org.heng.mq.producer;
//
//import lombok.RequiredArgsConstructor;
//import org.apache.rocketmq.client.producer.SendResult;
//import org.apache.rocketmq.spring.core.RocketMQTemplate;
//
//@RequiredArgsConstructor
//public abstract class AbstractMessageProducer<T> {
//    private final RocketMQTemplate rocketMQTemplate;
//
//    public abstract String buildDestinction();
//
//    public SendResult sendMessage(T message) {
//
//        return rocketMQTemplate.syncSend(
//                buildDestinction(),
//                message
//        );
//    }
//}
